package com.bonc.wkafka.utils.consumer.handler;

import java.util.Iterator;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface BadRecordsHandler<K, V> {

	int getRetryTimes();

	void handle(Iterator<ConsumerRecord<K, V>> records);

}
